//package com.wulaobo.test;
//
//import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
//import org.apache.flink.streaming.api.windowing.assigners.EventTimeSessionWindows;
//import org.apache.flink.streaming.api.windowing.assigners.GlobalWindows;
//import org.apache.flink.streaming.api.windowing.assigners.SlidingEventTimeWindows;
//import org.apache.flink.streaming.api.windowing.time.Time;
//
//
///**
// * @description:
// * @author： wuwenbo
// * @date： 2022-08-04 13:48
// */
//public class WindowDemo {
//
//    public static void main(String[] args) throws Exception {
//
//        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
//        env.setParallelism(1);
//
//        env.addSource(new ClickSource())
//                .keyBy()
////                .window(TumblingEventTimeWindows.of(Time.seconds(5)))
////                .window(SlidingEventTimeWindows.of(Time.seconds(10), Time.seconds(5)))
////                .window(EventTimeSessionWindows.withGap(Time.seconds(10)))
////                .countWindow(10)//计数窗口
//                .window(GlobalWindows.create())
//                .aggregate()
//
//        env.execute();
//
//    }
//
//}
